package com.hyjr.RxTask.demo;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class RxMsgController {
	private static BlockingQueue<RxMsg> queue = null;// new LinkedBlockingQueue<String>();
	private static RxMsgController _rxmsgController = null;

	public static RxMsgController GetInstance() {
		if (_rxmsgController == null) {
			queue = new LinkedBlockingQueue<RxMsg>();
			_rxmsgController = new RxMsgController();
			// obj = new object();
		}
		return _rxmsgController;
	}

	public BlockingQueue<RxMsg> GetRxMsgQueue() {
		return this.queue;
	}
}
